const path = require('path');
const sqlite3 = require('sqlite3').verbose();

let db;

function initializeDatabase(userDataPath) {
  const dbPath = path.join(userDataPath, 'data.db');

  // 连接到 SQLite 数据库文件
  db = new sqlite3.Database(dbPath, (err) => {
    if (err) {
      console.error(err);
    } else {
      console.log('已连接到数据库。');
    }
  });

  // 创建表格
  db.serialize(() => {
    db.run('CREATE TABLE IF NOT EXISTS users (id INT PRIMARY KEY, name TEXT)');
  });
}

function executeQuery(sql, callback) {
  // 执行查询操作
  db.all(sql, (err, rows) => {
    if (err) {
      console.error(err);
      callback(err, null);
    } else {
      console.log(rows);
      callback(null, rows);
    }
  });
}

function closeDatabase() {
  // 关闭数据库连接
  db.close((err) => {
    if (err) {
      console.error(err);
    } else {
      console.log('数据库连接已关闭。');
    }
  });
}

module.exports = {
  initializeDatabase,
  executeQuery,
  closeDatabase
};
